package Creating_Observables

import (
	"fmt"
	"github.com/reactivex/rxgo/v2"
	"time"
)

// 创建的可观察集合是一个可以定时重放的
func Demo_Repeat() {
	observable := rxgo.Just(1, 2, 3)().
		// 设置重放
		Repeat(3, rxgo.WithDuration(time.Second))
	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅：", item.E)
		}
		fmt.Println("订阅：", item.V)
	}
}
